import os

# from celery.app.base import Celery
from celery import Celery

# 指定项目setting文件, celery工作进程会使用到
# 需要在Celery应对创建之前指定
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "meiduo_mall.settings.dev")

# 创建celery应用(一个项目通常只需要一个celery应用)
# 参数1: 自定义的名字
celery_app = Celery('meiduo',
                    broker='redis://127.0.0.1:6379/15',
                    # 后台: 用来保存任务执行后的返回值
                    backend='redis://127.0.0.1:6379/14')

# 扫描任务函数，指定要在哪包下扫描，如果用了装饰器，就可以不用这样指定任务了
# celery_app.autodiscover_tasks(['celery_tasks.sms', 'celery_tasks.email'])


'''
celery_app = Celery('meiduo')
# 加载配置文件
celery_app.config_from_object('celery_tasks.config')
'''